package ods_config

import (
	"fmt"
	"server/global"
)

func StartOnceJob(jobId uint) (err error) {
	err = StopTmJob(jobId)
	if err != nil {
		return fmt.Errorf("停止任务失败:%s", err)
	}
	var m OdsDbConfig
	odsJob, err := m.GetJob(jobId)
	if err != nil {
		return err
	}

	global.JobRunning[odsJob.OdsTbName] = 1

	go func() {
		err := TmTaskHandler(jobId)
		if err != nil {
		}
	}()
	return nil
}

func StopOnceJob(jobId uint) (err error) {
	var m OdsDbConfig
	odsJob, err := m.GetJob(jobId)
	if err != nil {
		return err
	}

	delete(global.JobStart, odsJob.OdsTbName)
	delete(global.JobRunning, odsJob.OdsTbName)

	return nil
}
